from pyspark import SparkConf, SparkContext
# 创建SparkConf的实例对象
conf = SparkConf().setMaster("local[*]").setAppName("test_spark_app")  # 链式调用，因为这些方法返回的是对象自身(self)
# 基于SparkConf对象创建SparkContext对象
sc = SparkContext(conf=conf)
# 打印PySpark的运行版本
print(sc.version)
# 停止SparkContext对象的运行
sc.stop()